# # 生产者————任务————函数

# # １这个函数必须要让celery的实例的task装饰器装饰
# # ２需要celery自动检测指定包的任务
#
# from libs.yuntongxun.sms import CCP
# from celery_tasks.main import app
#
#
# @app.task
# def celery_send_sms_code(mobile, code):
#     CCP().send_template_sms(mobile, [code, 5], 1)




# 消费者

# celery -A proj worker -l INFO
# 在虚拟环境下执行
#     celery -A celery实例脚本路径 worker -l info




# # 队列（中间人，经纪人）
#
# # 设置broker
# # 通过加载配置文件来设置broker
# app.config_from_object('celery_tasks.config')
#
# # autodiscover_tasks参数是列表　列表中的元素是tasks路径
# app.autodiscover_tasks(['celery_tasks.sms'])

# # 配置信息　key=value
# # 我们指定了redis为我们的broker(中间人)
# broker_url = "redis://127.0.0.１:6379/15"



# # celery 将这三者实现
# # 为celery的运行　设置Django的环境
# import os
# os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'meiduo_mall.settings')
#
# # 创建celery实例
#
# from celery import Celery
#
# #1.main设置脚本路径就可以了，脚本路径是唯一的
# app = Celery('celery_tasks')
#
# # 设置broker
# # 通过加载配置文件来设置broker
# app.config_from_object('celery_tasks.config')
#
# # autodiscover_tasks参数是列表　列表中的元素是tasks路径
# app.autodiscover_tasks(['celery_tasks.sms'])